package com.xqc.rabbit.work;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.xqc.rabbit.ConnectionUtils;

/**
* @author 作者 Gavin.Dai/SNSSZ00036
* @dateTime 创建时间：2020年8月11日 下午1:09:15
* @version V1.0.0
* 类说明
*/
public class WorkProduct {
	public static final String WORK_QUEUE = "work_queue";

	public static void main(String[] args) throws IOException, TimeoutException {
		Connection conn = ConnectionUtils.getConn();
		//声明信道
		Channel channel = conn.createChannel();
		//声明队列,durable true声明一个持久队列（该队列将在服务器重新启动后继续存在）,exclusive=true声明独占队列（仅限于此连接）
		//autoDelete true服务器将在不再使用时删除它, arguments队列的其他属性
		channel.queueDeclare(WORK_QUEUE, true, false, false, null);
		//消息内容
		for (int i = 0; i < 100; i++) {
			String message = "工作对列模式--->"+i;
			//发布消息
			channel.basicPublish("", WORK_QUEUE, null, message.getBytes());
		}
		//关闭
		channel.close();
		conn.close();
	}
}
